package com.serwer;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class DownloadSpolki {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
String sql="SELECT distinct nazwa FROM notowania";	    

	    try {
	        Class.forName("com.mysql.jdbc.Driver");
	        Connection con= (Connection) DriverManager.getConnection("jdbc:mysql://localhost:3306/BROKER","root","");
	        Statement stmt=con.createStatement();
	        ResultSet rs = stmt.executeQuery(sql);
	        String Nazwa = null;	       
	        String allNazwa = "";	       
	       while (rs.next())
	      {
        //list sql
	    	   Nazwa = rs.getString("nazwa");

	    	   allNazwa+=Nazwa+';';   	    	   
	             
	      }	    
	      // System.out.println(allNazwa);
	       /*wyslanie do kolejki*/
	       ProducerSpolkiSend spolki = new ProducerSpolkiSend(allNazwa);
	     
	       }
	    catch(Exception e) {
	    
	    }
	}
}
